package com.yiruantong.common.core.config;

import jakarta.annotation.PreDestroy;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.concurrent.BasicThreadFactory;
import com.yiruantong.common.core.config.properties.ThreadPoolProperties;
import com.yiruantong.common.core.utils.Threads;
import org.springframework.boot.autoconfigure.AutoConfiguration;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.ThreadPoolExecutor;

/**
 * 线程池配置
 *
 * @author YiRuanTong
 **/
@Slf4j
@AutoConfiguration
@EnableConfigurationProperties(ThreadPoolProperties.class)
public class ThreadPoolConfig {

  /**
   * 核心线程数 = cpu 核心数 + 1
   */
  private final int core = Runtime.getRuntime().availableProcessors() + 1;

  private ScheduledExecutorService scheduledExecutorService;

  @Bean(name = "threadPoolTaskExecutor")
  @ConditionalOnProperty(prefix = "thread-pool", name = "enabled", havingValue = "true")
  public ThreadPoolTaskExecutor threadPoolTaskExecutor(ThreadPoolProperties threadPoolProperties) {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(core);
    executor.setMaxPoolSize(core * 2);
    executor.setQueueCapacity(threadPoolProperties.getQueueCapacity());
    executor.setKeepAliveSeconds(threadPoolProperties.getKeepAliveSeconds());
    executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
    return executor;
  }

  /**
   * 执行周期性或定时任务
   */
  @Bean(name = "scheduledExecutorService")
  protected ScheduledExecutorService scheduledExecutorService() {
    ScheduledThreadPoolExecutor scheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(core,
      new BasicThreadFactory.Builder().namingPattern("schedule-pool-%d").daemon(true).build(),
      new ThreadPoolExecutor.CallerRunsPolicy()) {
      @Override
      protected void afterExecute(Runnable r, Throwable t) {
        super.afterExecute(r, t);
        Threads.printException(r, t);
      }
    };
    this.scheduledExecutorService = scheduledThreadPoolExecutor;
    return scheduledThreadPoolExecutor;
  }

  /**
   * 销毁事件
   */
  @PreDestroy
  public void destroy() {
    try {
      log.info("====关闭后台任务任务线程池====");
      Threads.shutdownAndAwaitTermination(scheduledExecutorService);
    } catch (Exception e) {
      log.error(e.getMessage(), e);
    }
  }

}
